--[[
    编码: JX-116-10
    名称: 巨沃料箱初始化-导入
    作者：HAN    
    日期：2025-1-29    
    入口函数： Import

    功能说明:

    变更历史:

--]]
wms_base = require ("wms_base")
wms_cntr= require( "wms_container" )

function Import(strLuaDEID)
    local nRet, strRetInfo, strNo

    -- 获取导入的数据, 返回 [{"attr":"xx","value":""},...]
    local row_data = {}
    nRet, row_data = m3.GetSysDataJson(strLuaDEID)
    if (nRet ~= 0 or strRetInfo == '') then lua.Error( strLuaDEID, debug.getinfo(1), "无法获取导入数据!") end

    local row_attrs
    local n, nCount, nRows, nIndex
    local cntr_type, max_cell_num

    -- 导入是可分多页分批导入， 因此每次的起始行不一样
    nRet, strRetInfo = mobox.getGlobalAttrValue( strLuaDEID, "start_row" )
    if ( nRet ~= 0 ) then
        mobox.error( strLuaDEID, "获取批量导入全局参数 start_row 失败!"..strRetInfo )
        return
    end    
    local nStartRow = tonumber( strRetInfo )
    local err_msg_list = {}                          -- 用于写导入错误信息
    local str_err_msg
    local jw_cntr, cntr
    local strCondition, strUpdateSql
    local item_code, item_name, cell_no
    local qty
    local material
    local cg_detail

    -- 步骤1 获取从excel导入的一行数据
    nRow = nStartRow
    for row = 1, #row_data do
        row_attrs = row_data[row]

        -- 初始化空料箱对象
        item_code = ''
        item_name = ''
        cell_no = ''
        qty = 0
        jw_cntr = m3.AllocObject(strLuaDEID,"JW_CNTR_Goods_INIT")
        str_err_msg = ''
        for n = 1, #row_attrs do
            strAttr = row_attrs[n].attr
            strValue = row_attrs[n].value
            if (strAttr ~= '') then
                if (strAttr == "料箱编码") then
                    if (strValue == '') then 
                        str_err_msg = strAttr .. "不能为空!"
                        goto err_msg_process
                    end
                    jw_cntr.cntr_code = strValue
                elseif (strAttr == "料箱类型") then
                    if (strValue == '') then 
                        str_err_msg = strAttr .. "不能为空!"
                        goto err_msg_process
                    end                  
                    jw_cntr.spec = strValue
                elseif (strAttr == "料格") then
                    cell_no = strValue
                elseif (strAttr == "料号") then
                    item_code = strValue                   
                elseif (strAttr == "品名") then
                    item_name = strValue
                elseif (strAttr == "数量") then
                    qty = lua.StrToNumber( strValue )  
                end
            end
        end

        -- 首先判断一下容器是否存在，容器已经存在不允许导入，可以考虑先在WMS中删除
        nRet, cntr = wms_cntr.GetInfo( strLuaDEID, jw_cntr.cntr_code )
        if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "获取容器信息失败!"..cntr ) end

        if ( cntr == '' ) then
            -- 没有容器需要创建
            nRet, jw_cntr = m3.CreateDataObj(strLuaDEID, jw_cntr)
            if (nRet ~= 0 ) then 
                str_err_msg = "创建巨沃初始化料箱货品对象失败!"..jw_cntr 
                goto err_msg_process
            end  

            cntr = m3.AllocObject(strLuaDEID,"Container")
            cntr.code = jw_cntr.cntr_code
            cntr.type = 3           -- 料箱
            cntr.spec = jw_cntr.spec
            cntr.source = "巨沃"
            nRet, cntr = m3.CreateDataObj(strLuaDEID, cntr)
            if (nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "创建料箱对象失败!"..cntr ) end                  
        else
            -- 容器已经存在需要判断容器是否和货位有绑定
            if ( cntr.position ~= '' ) then
                str_err_msg = "料箱'"..jw_cntr.cntr_code.."'已经在储藏区，不能导入!"
                goto err_msg_process
            end
        end
        -- 判断是否要导入 CG_Detail
        if ( item_code ~= '' and cell_no ~= '') then
            nRet, material = m3.GetDataObjectByKey(strLuaDEID, "SKU", "S_ITEM_CODE", item_code )
            if (nRet ~= 0 ) then 
                if ( nRet == 1 ) then
                    str_err_msg = material
                    goto err_msg_process
                end
                lua.Error( strLuaDEID, debug.getinfo(1), "获取货品信息失败!"..material )    
            end

            -- 判断一下CG_Detail 里相同的货品不能有（防止重复导入造成数据错误）
            strCondition = "S_CNTR_CODE = '"..jw_cntr.cntr_code.."' AND S_CELL_NO = '"..cell_no.."' AND S_ITEM_CODE = '"..item_code.."'"
            nRet, strRetInfo = mobox.existThisData( strLuaDEID, "CG_Detail", strCondition )
            if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo )  end
            if ( strRetInfo ~= "yes" ) then 
                cg_detail = m3.AllocObject(strLuaDEID,"CG_Detail")
                cg_detail.cntr_code = jw_cntr.cntr_code
                cg_detail.cell_no = cell_no
                cg_detail.item_code = item_code
                cg_detail.item_name = item_name
                cg_detail.weight = material.weight
                cg_detail.volume = material.volume
                cg_detail.qty = qty
                cg_detail.uom = "个"
                nRet, cg_detail = m3.CreateDataObj( strLuaDEID, cg_detail )
                if ( nRet ~= 0 ) then 
                    lua.Error( strLuaDEID, debug.getinfo(1), '创建拣料箱CG_Detail时失败!'..cg_detail ) 
                end   
            end           
        end

        ::err_msg_process::
        if ( str_err_msg ~= '' ) then
            local err_msg_row = {
                row_no = nRow,
                err_msg = str_err_msg
            }
            table.insert( err_msg_list, err_msg_row )            
        end
        nRow = nRow + 1
    end
    -- 把导入过程中的错误信息返回到前端
    local import_fail = {
        result = {
            fail = err_msg_list
        }
    }
    mobox.returnValue( strLuaDEID,1, lua.table2str(import_fail) )
    lua.Debug( strLuaDEID, debug.getinfo(1), "import_fail", import_fail )    
end